package com.yg.edu.list;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @author ：杨过
 * @date ：Created in 2020/8/23
 * @version: V1.0
 * @slogan: 天下风云出我辈，一入代码岁月催
 * @description:
 **/
public class CopyOnWriteArrayListRunner {
    /**
     * 读线程
     * @author wangjie
     *
     */
    private static class ReadTask implements Runnable {
        List<String> list;

        public ReadTask(List<String> list) {
            this.list = list;
        }

        public void run() {
            for (String str : list) {
                System.out.println("method-ReadTask："+str);
            }
        }
    }
    /**
     * 写线程
     * @author wangjie
     *
     */
    private static class WriteTask implements Runnable {
        List<String> list;
        int index;

        public WriteTask(List<String> list, int index) {
            this.list = list;
            this.index = index;
        }

        public void run() {
            list.remove(index);
            list.add(index, "method-WriteTask：write_" + index);
        }
    }

    public void run() {
        final int NUM = Runtime.getRuntime().availableProcessors();
        List<String> list = new CopyOnWriteArrayList<>();//new ArrayList<String>();
        for (int i = 0; i < NUM; i++) {
            list.add("main_" + i);
        }
        ExecutorService executorService = Executors.newFixedThreadPool(NUM);
        for (int i = 0; i < NUM; i++) {
            executorService.execute(new ReadTask(list));
            executorService.execute(new WriteTask(list, i));
            System.out.println("-------");
        }
        executorService.shutdown();
    }


    /**
     *
     * 核心思想:读写分离，空间换时间，避免为保证并发安全导致的激烈的锁竞争。
     * 划关键点:
     * 1、CopyOnWrite适用于读多写少的情况，最大程度的提高读的效率;
     * 2、CopyOnWrite是最终一致性，在写的过程中，原有的读的数据是不会发生更新的，只有新的读 才能读到最新数据;
     * 3、如何使其他线程能够及时读到新的数据，需要使用volatile变量;
     * 4、写的时候不能并发写，需要对写操作进行加锁;
     *
     *
     *
     * 理解：读内容是单纯的读取数据输出；   写任务：是先移除数据再重新放入新数据；
     *
     * 输出内容：
     * method-ReadTask：main_0
     * method-ReadTask：main_1
     * method-ReadTask：main_2
     * method-ReadTask：main_3
     * -------
     * method-ReadTask：method-WriteTask：write_0
     * method-ReadTask：main_1
     * method-ReadTask：main_2
     * method-ReadTask：main_3
     * -------
     * method-ReadTask：method-WriteTask：write_0
     * method-ReadTask：method-WriteTask：write_1
     * method-ReadTask：main_2
     * method-ReadTask：main_3
     * -------
     * method-ReadTask：method-WriteTask：write_0
     * method-ReadTask：method-WriteTask：write_1
     * method-ReadTask：method-WriteTask：write_2
     * method-ReadTask：main_3
     * -------
     * @param args
     * @return void
     * @author fwh [2022/2/26 && 4:46 下午]
     */
    public static void main(String[] args) {
        new CopyOnWriteArrayListRunner().run();
    }
}
